Visual Basic (Declaration) | |
---|---|
Public Function Complete( _ ByVal completePending As Boolean, _ ByVal timeout As Integer _ ) As Boolean |
C# | |
---|---|
public bool Complete( bool completePending, int timeout ) |
Parameters
- completePending
- True to complete enqueued activities
- timeout
- The timeout to wait for a thread before Abort() is called
Exception | Description |
---|---|
System.ApplicationException | The exception that is thrown when a non-fatal application error occurs. |
Library/Library.Test/TestWorkQueue.cs
C# | Copy Code |
---|---|
int[] counter = new int[1]; using (WorkQueue<int[]> worker = new WorkQueue<int[]>(ProcessOne, Math.Max(2, Environment.ProcessorCount))) { for (int i = 0; i < 1000; i++) worker.Enqueue(counter); worker.Complete(false, 10); } Assert.AreNotEqual(0, counter[0]); |
VB.NET | Copy Code |
---|---|
Dim counter As Integer() = New Integer(1) {} Using worker As New WorkQueue(Of Integer())(ProcessOne, Math.Max(2, Environment.ProcessorCount)) Dim i As Integer = 0 While i < 1000 worker.Enqueue(counter) System.Math.Max(System.Threading.Interlocked.Increment(i),i - 1) End While worker.Complete(False, 10) End Using Assert.AreNotEqual(0, counter(0)) |
Target Platforms: Windows XP, Windows Server 2003, Windows Vista, Windows Server 2008, Windows 7
Reference
WorkQueue<T> ClassWorkQueue<T> Members
Used By
ThreadedBTreeTest.TestAtomicUpdate()ThreadedBTreeTest.TestErrorsOnInsertAndDelete()
ThreadedBTreeTest.TestConcurrentCreateReadUpdateDelete8000()
Boolean SecureTransfer.Client.Upload(String,Int64,Stream)